package com.ql.consumer.service;



import com.ql.consumer.service.impl.IMessageComsumer;

import java.util.List;

public class ConsumerManager {

    public void registerConsumer(String consumerName,  final IMessageComsumer icomsumer) throws Exception {
        List<String> topics = icomsumer.getTopics();
        icomsumer.onReceiveMessage(consumerName,topics.get(0));
    }



}
